"""
生产者(任务函数)
        from libs.yuntongxun.sms import CCP
        from celery_tasks.main import app
        @app.task
        def celery_send_sms_code(moblie,code):
            CCP().send_template_sms(moblie,[code,5],1)

        app.autodiscover_tasks(['celery_task.sms'])
消费者
        celery -A proj worker -l INFO
        在win系统中推荐使用 gevent 或 eventlet 代替默认的 prefork：
        # 安装 gevent
        pip install gevent
        # 使用 gevent 启动 Celery
        celery -A celery_tasks.main worker -l INFO -P gevent


        在终端执行指令
        celery -A celery实例的脚本路径 worker -l INFO

队列（中间人，经纪人）
        #2. 设置broker
        #我们通过加载配置文件来设置broker
        app.config_from_object('celery_tasks.config')
        #配置信息 key= value
        #指定redis为我们的broker（中间人，经纪人，队列）
        broker_url="redis://172.0.0.1:6379/15"
Celery --将三者实现
        #1. 为celery的运行 设置django的环境
        import os
        os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo_mall.settings')
        #2.创建celery实例
        from celery import Celery
        #参数1：main 设置脚本路径就可以了，脚本路径是唯一的
        app=Celery('celery_tasks')
"""
#1. 为celery的运行 设置django的环境
import os
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo_mall.settings')
#2.创建celery实例
from celery import Celery
#参数1：main 设置脚本路径就可以了，脚本路径是唯一的
app=Celery('celery_tasks')

#2. 设置broker
#我们通过加载配置文件来设置broker
app.config_from_object('celery_tasks.config')

#3.需要celery自动检测指定包的任务
#autodiscover_tasks 参数是列表
#列表中的元素是 tasks的路径
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])